﻿using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;


namespace SisEagleBO
{

    /// <summary>
    /// Classe BO: Business Objects
    /// Criador: Rafael da Silva França
    /// Criada em 08/09/2012
    /// Contato: rafael.sfranca@gmail.com
    /// </summary>
    public partial class ControleEstoqueBO
    {
        #region Singleton
        private SisEagleBO.ProdutosBO _ProdutosBusiness;
        private SisEagleBO.ProdutosBO ProdutosBusiness
        {
            get
            {
                if (_ProdutosBusiness == null)
                    _ProdutosBusiness = new SisEagleBO.ProdutosBO();

                return _ProdutosBusiness;
            }
        }

        #endregion


        // Atributos
        private SisEagleDO.SisEagleDO objDO = null;
        private StringBuilder strSql = null;

        //Métodos
        /// <summary>
        /// Seleciona todos os registros e retorna um DataSet.
        /// </summary>
        /// <returns>DataSet</returns>
        public DataSet FindAll()
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT Produtos.NomeProduto, ControleEstoque.CodProduto, ControleEstoque.Quantidade, ControleEstoque.QuantidadeMinima FROM ControleEstoque INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto");
                //strSql.Append(" SELECT ");
                //// colunas
                //strSql.Append(" CodProduto, Quantidade, QuantidadeMinima  ");
                //strSql.Append(" FROM  ControleEstoque  ");

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros com ordenação e retorna um DataSet.
        /// </summary>
        /// <param name="_orderby">campo de ordenação</param>
        /// <returns>DataSet</returns>
        public DataSet FindAll(string _orderby)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT Produtos.NomeProduto, ControleEstoque.CodProduto, ControleEstoque.Quantidade,");
                strSql.Append(" ControleEstoque.QuantidadeMinima FROM ControleEstoque");
                strSql.Append(" INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto ORDER BY " + _orderby );
                //strSql.Append(" SELECT ");
                //// colunas
                //strSql.Append(" CodProduto, Quantidade, QuantidadeMinima  ");
                //strSql.Append(" FROM  ControleEstoque  ");
                //strSql.Append(" ORDER BY " + _orderby);

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros com filtro.
        /// </summary>
        /// <param name="_filtro ("id_campo = 1 AND campo1 = 'texto' OR campo2 LIKE 'r%'")">filtro da consulta</param>
        /// <returns>DataSet</returns>
        public DataSet FindByWhere(string _filtro)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT Produtos.NomeProduto, ControleEstoque.CodProduto, ControleEstoque.Quantidade,");
                strSql.Append(" ControleEstoque.QuantidadeMinima FROM ControleEstoque");
                strSql.Append(" INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto ORDER BY " + _filtro);
                strSql.Append(" WHERE ( " + _filtro + " ) ");

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros com filtro e ordenação.
        /// </summary>
        /// <param name="_filtro ("id_campo = 1 AND campo1 = 'texto' OR campo2 LIKE 'r%'")">filtro da consulta</param>
        /// <param name="_orderby">campo de ordenação</param>
        /// <returns>DataSet</returns>
        public DataSet FindByWhere(string _filtro, string _orderby)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT Produtos.NomeProduto, ControleEstoque.CodProduto, ControleEstoque.Quantidade,");
                strSql.Append(" ControleEstoque.QuantidadeMinima FROM ControleEstoque");
                strSql.Append(" INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto ORDER BY " + _filtro);
                strSql.Append(" WHERE ( " + _filtro + " ) ");
                strSql.Append(" ORDER BY " + _orderby);
               
                //strSql.Append(" SELECT ");
                //// colunas
                //strSql.Append(" CodProduto, Quantidade, QuantidadeMinima  ");
                //strSql.Append(" FROM  ControleEstoque  ");
                //strSql.Append(" WHERE ( " + _filtro + " ) ");
                //strSql.Append(" ORDER BY " + _orderby);

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros por CodProduto.
        /// </summary>
        /// <param name="_CodProduto">filtro da consulta</param>
        /// <returns>DataSet</returns>
        public DataSet FindBy_CodProduto(int _CodProduto)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT     ControleEstoque.CodProduto, Produtos.NomeProduto, ControleEstoque.Quantidade, ControleEstoque.QuantidadeMinima FROM ControleEstoque ");
                strSql.Append("INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto");
                strSql.Append(" WHERE (  ControleEstoque.CodProduto =   " + _CodProduto + "  ) ");
                //strSql.Append(" SELECT ");
                //// colunas
                //strSql.Append(" CodProduto, Quantidade, QuantidadeMinima  ");
                //strSql.Append(" FROM  ControleEstoque  ");
                //strSql.Append(" WHERE (  CodProduto =   " + _CodProduto + "  ) ");

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros por CodProduto.
        /// </summary>
        /// <param name="_CodProduto">filtro da consulta</param>
        /// <param name="_orderby">campo de ordenação</param>
        /// <returns>DataSet</returns>
        public DataSet FindBy_CodProduto(int _CodProduto, string _orderby)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT     ControleEstoque.CodProduto, Produtos.NomeProduto, ControleEstoque.Quantidade, ControleEstoque.QuantidadeMinima FROM ControleEstoque ");
                strSql.Append("INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto");
                strSql.Append(" WHERE (  ControleEstoque.CodProduto =   " + _CodProduto + "  ) ");
                strSql.Append(" ORDER BY " + _orderby);

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros por Quantidade.
        /// </summary>
        /// <param name="_Quantidade">filtro da consulta</param>
        /// <returns>DataSet</returns>
        public DataSet FindBy_Quantidade(int _Quantidade)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT     ControleEstoque.CodProduto, Produtos.NomeProduto, ControleEstoque.Quantidade, ControleEstoque.QuantidadeMinima FROM ControleEstoque ");
                strSql.Append("INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto");
                strSql.Append(" WHERE   Quantidade =   " + _Quantidade );

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros por Quantidade.
        /// </summary>
        /// <param name="_Quantidade">filtro da consulta</param>
        /// <param name="_orderby">campo de ordenação</param>
        /// <returns>DataSet</returns>
        public DataSet FindBy_Quantidade(int _Quantidade, string _orderby)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT     ControleEstoque.CodProduto, Produtos.NomeProduto, ControleEstoque.Quantidade, ControleEstoque.QuantidadeMinima FROM ControleEstoque ");
                strSql.Append("INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto");
                strSql.Append(" WHERE (  Quantidade =   " + _Quantidade);
                strSql.Append(" ORDER BY " + _orderby);

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros por QuantidadeMinima.
        /// </summary>
        /// <param name="_QuantidadeMinima">filtro da consulta</param>
        /// <returns>DataSet</returns>
        public DataSet FindBy_QuantidadeMinima(int _QuantidadeMinima)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append("SELECT     ControleEstoque.CodProduto, Produtos.NomeProduto, ControleEstoque.Quantidade, ControleEstoque.QuantidadeMinima FROM ControleEstoque ");
                strSql.Append("INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto");
                strSql.Append(" WHERE  Quantidade =   " + _QuantidadeMinima);

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Seleciona todos os registros por QuantidadeMinima.
        /// </summary>
        /// <param name="_QuantidadeMinima">filtro da consulta</param>
        /// <param name="_orderby">campo de ordenação</param>
        /// <returns>DataSet</returns>
        public DataSet FindBy_QuantidadeMinima(int _QuantidadeMinima, string _orderby)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append(" SELECT ");
                // colunas
                strSql.Append("SELECT     ControleEstoque.CodProduto, Produtos.NomeProduto, ControleEstoque.Quantidade, ControleEstoque.QuantidadeMinima FROM ControleEstoque ");
                strSql.Append("INNER JOIN Produtos ON ControleEstoque.CodProduto = Produtos.CodProduto");
                strSql.Append(" WHERE (  QuantidadeMinima =   " + _QuantidadeMinima + "  ) ");
                strSql.Append(" ORDER BY " + _orderby);

                objDO = new SisEagleDO.SisEagleDO();

                // executa consulta e retorna um DataSet
                return objDO.GetDataSet(strSql.ToString(), "ControleEstoque");
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Insere os registros do banco e retorna o número de linhas afetadas.
        /// </summary>
        /// <param name="_vo">objetos vo do banco</param>
        /// <returns>int</returns>
        public int Insert(SisEagleVO.ControleEstoqueVO _vo)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append(" INSERT INTO  ControleEstoque  ");
                strSql.Append(" (");
                strSql.Append(" CodProduto, ");
                strSql.Append(" Quantidade, ");
                strSql.Append(" QuantidadeMinima ");
                strSql.Append(" ) ");
                strSql.Append(" VALUES (");
                strSql.Append(" " + _vo.CodProduto + " , ");
                strSql.Append(" " + _vo.Quantidade + " , ");
                strSql.Append(" " + _vo.QuantidadeMinima + "  )");


                objDO = new SisEagleDO.SisEagleDO();

                // executa comando e retorna o número de linhas afetadas.
                return objDO.ExecutaQuery(strSql.ToString());
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Atualiza os registros do banco e retorna o número de linhas afetadas.
        /// </summary>
        /// <param name="_vo">objetos vo do banco</param>
        /// <returns>int</returns>
        public int Update(SisEagleVO.ControleEstoqueVO _vo)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append(" UPDATE  ControleEstoque  ");
                strSql.Append(" SET ");

                strSql.Append("   Quantidade =   " + _vo.Quantidade + " ,  ");
                strSql.Append("   QuantidadeMinima =   " + _vo.QuantidadeMinima + "   ");

                strSql.Append(" WHERE ( CodProduto =   " + _vo.CodProduto + "  ) ");

                objDO = new SisEagleDO.SisEagleDO();

                // executa comando e retorna o número de linhas afetadas.
                return objDO.ExecutaQuery(strSql.ToString());
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

        /// <summary>
        /// Deleta os registros do banco e retorna o número de linhas afetadas.
        /// </summary>
        /// <param name="_vo">objetos vo do banco</param>
        /// <returns>int</returns>
        public int Delete(SisEagleVO.ControleEstoqueVO _vo)
        {
            try
            {
                strSql = new StringBuilder();
                strSql.Append(" DELETE FROM ControleEstoque  ");
                strSql.Append(" WHERE ( CodProduto = " + _vo.CodProduto + " ) ");

                objDO = new SisEagleDO.SisEagleDO();

                // executa comando e retorna o número de linhas afetadas.
                return objDO.ExecutaQuery(strSql.ToString());
            }
            catch (Exception er)
            {
                throw new Exception("Aconteceu um erro:" + er.Message.ToString());
            }
            finally
            {
                strSql = null;
            }
        }

    }

}